projects / flume-search.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(initial) | patch
Fork the sink from main flume build master
authorRalph Goers <rgoers@apache.org>
Mon, 4 Apr 2022 08:44:16 +0000 (01:44 -0700)
committerRalph Goers <rgoers@apache.org>
Mon, 4 Apr 2022 08:44:16 +0000 (01:44 -0700)
commit3d096e5634328892625d526f73eadf37af575684
treea745a88f2fb03729027c3a5f58c3e164028f5c6ctree | snapshot
Fork the sink from main flume build
37 files changed:
.github/workflows/build.yml [new file with mode: 0644] blob
.github/workflows/codeql-analysis.yml [new file with mode: 0644] blob
.gitignore [new file with mode: 0644] blob
flume-elasticsearch-sink/pom.xml [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchIndexRequestBuilderFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ContentBuilderUtil.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchDynamicSerializer.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchEventSerializer.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchIndexRequestBuilderFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchLogStashEventSerializer.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSinkConstants.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/EventSerializerIndexRequestBuilderFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/IndexNameBuilder.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/SimpleIndexNameBuilder.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/TimeBasedIndexNameBuilder.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/TimestampedEvent.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClient.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/NoSuchClientTypeException.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchSinkTest.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchDynamicSerializer.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchIndexRequestBuilderFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchLogStashEventSerializer.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSink.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TestElasticSearchSinkCreation.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TimeBasedIndexNameBuilderTest.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/TimestampedEventTest.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/RoundRobinListTest.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/TestElasticSearchClientFactory.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/TestElasticSearchRestClient.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/TestElasticSearchTransportClient.java [new file with mode: 0644] blob
flume-elasticsearch-sink/src/test/resources/log4j2.xml [new file with mode: 0644] blob
pom.xml [new file with mode: 0644] blob
Apache flume search components