public ElasticsearchJestSink()

in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/ElasticsearchJestSink.java [66:74]

• 8 lines of code
• 1 McCabe index (conditional complexity)

  public ElasticsearchJestSink(Map<String, String> config, String indexName, String documentType, int batchSize, long maxBufferTime) {
    this.userConfig = config;
    this.indexName = indexName;
    this.documentType = documentType;
    this.batchSize = batchSize;
    this.maxBufferTime = maxBufferTime;

    this.lastBufferFlush = System.currentTimeMillis();
  }