Package | Description |
---|---|
org.apache.flink.streaming.tests |
Modifier and Type | Method and Description |
---|---|
static <K extends Comparable<? super K>,T1 extends Comparable<? super T1>> |
KeyValue.of(K key,
T1 value)
Creates a new key-value pair.
|
Modifier and Type | Method and Description |
---|---|
List<KeyValue<Integer,String>> |
Elasticsearch7Client.fetchAll(QueryParams params) |
List<KeyValue<Integer,String>> |
Elasticsearch6Client.fetchAll(QueryParams params) |
List<KeyValue<Integer,String>> |
ElasticsearchClient.fetchAll(QueryParams params)
Fetch all results from the index.
|
List<KeyValue<Integer,String>> |
ElasticsearchDataReader.poll(java.time.Duration timeout) |
Modifier and Type | Method and Description |
---|---|
int |
KeyValue.compareTo(KeyValue<K,V> other) |
org.elasticsearch.action.update.UpdateRequest |
UpdateRequest7Factory.createUpdateRequest(KeyValue<Integer,String> element) |
org.elasticsearch.action.update.UpdateRequest |
UpdateRequest6Factory.createUpdateRequest(KeyValue<Integer,String> element) |
org.elasticsearch.action.update.UpdateRequest |
UpdateRequestFactory.createUpdateRequest(KeyValue<Integer,String> element) |
void |
ElasticsearchTestEmitter.emit(KeyValue<Integer,String> element,
SinkWriter.Context context,
RequestIndexer indexer) |
static Map<String,Object> |
UpdateRequestFactory.prepareDoc(KeyValue<Integer,String> element)
Utility to convert
KeyValue elements into Elasticsearch-compatible format. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.