mitch-seymour

I have modified the force-multi-foci example to add a convex hull around each cluster of nodes.

I achieved this by using d3.nest() to create a new dataset of clusters containing the nodes in each cluster. Then in the tick() method I create and update the path element for each cluster in this dataset.

mitch-seymour

height: 700
license: mit

mitch-seymour

height: 660
license: mit

mitch-seymour

class StreamsApp {
    // properties, methods, etc
    
    public void forceInitializationOfStateStore(Map<String, Object> config, String sourceTopic, Deserializer keyDeserializer, Deserializer valueDeserializer) {
          config.put(ENABLE_AUTO_COMMIT_CONFIG, true);
          KafkaConsumer<String, String> consumer = new KafkaConsumer<>(config, keyDeserializer, valueDeserializer);
          ConsumerRebalanceListener listener = new ConsumerRebalanceListener() {
              public void onPartitionsRevoked (Collection< TopicPartition > partitions) {}
              public void onPartitionsAssigned (Collection < TopicPartition > partitions) {
                  List<TopicPartition> unInitialized = new ArrayList<>();

mitch-seymour

Guest blog post proposal

I'd love to contribute a guest blog post to highlight a simpler method for getting started with KSQL UDFs / UDAFs. We would need to merge [KSQL #2272][pr] first, potentially add a closing section to this article, and get the content reviewed by Confluent of course :)

Author

Mitch Seymour

mitch-seymour

Make sure you have avro-tools installed.

brew install avro-tools

# or...
mvn dependency:get -Dartifact=org.apache.avro:avro-maven-plugin:1.8.2
cp ~/.m2/repository/org/apache/avro/avro-tools/1.8.2/avro-tools-1.8.2.jar /usr/local/bin/avro-tools

mitch-seymour

# no args example
$ ./build/graal/hello-world

# output
Hello world :)

# args example
$ ./build/graal/hello-world --help

# output

mitch-seymour

dependencies {
    compile 'info.picocli:picocli:4.1.0'
    annotationProcessor 'info.picocli:picocli-codegen:4.1.0'
    
    // ...
}

compileJava {
    sourceCompatibility = JavaVersion.VERSION_1_8
    targetCompatibility = JavaVersion.VERSION_1_8

mitch-seymour

# create a new project directory
$ mkdir graal-cli-example && cd graal-cli-example

# init a new project
$ gradle init \
  --type java-application \
  --dsl groovy \
  --test-framework junit-jupiter \
  --project-name hi \
  --package com.mitchseymour.hi

mitch-seymour

# verify that it can be built / executed
$ ./gradlew run

# output
> Task :run
Hello world.