Skip to content

Instantly share code, notes, and snippets.

View mrsimpson's full-sized avatar

Oliver Jägle mrsimpson

44 followers · 6 following
  • DB Systel GmbH
  • Lorsch, Germany
View GitHub Profile
@mrsimpson
mrsimpson / q-conversation.json
Created October 23, 2025 08:57
Sample conversation agentic-knowledge
{
"conversation_id": "8a174edc-00a5-4206-bf95-e9c3f31ea959",
"next_message": null,
"history": [
{
"user": {
"additional_context": "",
"env_context": {
"env_state": {
"operating_system": "macos",
@mrsimpson
mrsimpson / Schreiben eine Blogposts mit Responsible-Vibe-MCP
Created July 2, 2025 14:03
{
"conversation_id": "f44d245a-20e5-4950-99cd-838deb32d7b8",
"next_message": null,
"history": [
[
{
"additional_context": "--- CONTEXT ENTRY BEGIN ---\nThis section (like others) contains important information that I want you to use in your responses. I have gathered this context from valuable programmatic script hooks. You must follow any requests and consider all of the information in this section\n\n--- CONTEXT ENTRY END ---\n\n",
"env_context": {
"env_state": {
"operating_system": "macos",
@mrsimpson
mrsimpson / conversation.json
Created June 30, 2025 20:00
q-developer: Polish bolt.new's amazing one-shot
{
"conversation_id": "14ee9ee5-5d16-4dd3-8b58-a41fe3d9ec4e",
"next_message": null,
"history": [
[
{
"additional_context": "--- CONTEXT ENTRY BEGIN ---\nThis section (like others) contains important information that I want you to use in your responses. I have gathered this context from valuable programmatic script hooks. You must follow any requests and consider all of the information in this section\n\n'git-status': \n\n--- CONTEXT ENTRY END ---\n\n",
"env_context": {
"env_state": {
"operating_system": "macos",
@mrsimpson
mrsimpson / 3-10.md
Last active July 3, 2025 20:38
Sample for responsible-vibe-mcp

Implementation of the context-feature

This conversation is a recorded vibe coding of how I added the feature to display context information alongside the conversation flow.

@mrsimpson
mrsimpson / Readme.md
Last active January 13, 2025 07:45
Serialization of files from multiple folders

Project Serializer

Purpose

A flexible shell function to serialize source code directories into a single text stream, useful for preprocessing code for LLM analysis or code review.

Features

  • Serialize multiple project directories
  • Include/exclude file patterns
  • Skip binary files
  • Verbose mode for debugging
@mrsimpson
mrsimpson / motivation.md
Last active May 23, 2024 12:46
Warum Flink

Apache Flink

Apache Flink ist eine Open-Source-Stream-Processing-Engine, die für verteilte, hochparallele und fehlertolerante Datenströme entwickelt wurde. Es ermöglicht die Verarbeitung von kontinuierlichen Datenströmen in Echtzeit.

Integration mit Apache Kafka

Apache Flink integriert sich nahtlos mit Apache Kafka, dem de-facto-Standard für Datenströme:

  • Flink kann Kafka-Topics als Datenquellen nutzen und Ergebnisse in Kafka-Topics schreiben[1][4]
  • Flink unterstützt die exakt-einmalige Verarbeitung von Ereignissen, selbst bei Systemausfällen[4]
@mrsimpson
mrsimpson / BroadcastStreamDemoJob.java
Created January 10, 2024 09:45
Broadcasting in Flink
package de.fermata.flink.app;
import java.time.Instant;
import java.util.Random;
import java.util.stream.StreamSupport;
import org.apache.flink.api.common.state.BroadcastState;
import org.apache.flink.api.common.state.MapStateDescriptor;
import org.apache.flink.api.common.state.ReadOnlyBroadcastState;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.configuration.Configuration;
@mrsimpson
mrsimpson / EventSortJob.java
Created January 10, 2024 09:43
Flink sorting with windows
package de.fermata.flink.app;
import java.time.Duration;
import java.util.stream.StreamSupport;
import org.apache.flink.api.common.eventtime.*;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.sink.PrintSinkFunction;
import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction;
import org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows;
@mrsimpson
mrsimpson / BufferedSorter.java
Last active November 28, 2023 14:37
Buffered sorter for a window in Flink
import java.sql.Timestamp;
import java.util.Comparator;
import java.util.Optional;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
import org.apache.flink.api.common.state.ListState;
import org.apache.flink.api.common.state.ListStateDescriptor;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.configuration.Configuration;
@mrsimpson
mrsimpson / ControllableSourceFunction.java
Last active March 12, 2025 16:27
Controllable Source Function for Flink integration testing testing a complete pipeline
package de.db.lightgate.streaming.functions;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CountDownLatch;
import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction;
import org.apache.flink.streaming.api.watermark.Watermark;