| Constructor <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (DefaultBulkResponseInspector.java:45) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (OpensearchSink.java:75) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:74) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:76) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:77) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:78) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:79) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:80) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, org.apache.flink.connector.base.DeliveryGuarantee, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSink.java:81) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter$DefaultRequestIndexer.<init>(org.apache.flink.connector.opensearch.sink.OpensearchWriter, org.apache.flink.metrics.Counter)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:295) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:100) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:102) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:105) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:111) |
| Constructor <org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List, org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean, org.apache.flink.connector.opensearch.sink.BulkProcessorConfig, org.apache.flink.connector.opensearch.sink.NetworkClientConfig, org.apache.flink.metrics.groups.SinkWriterMetricGroup, org.apache.flink.api.common.operators.MailboxExecutor, org.apache.flink.connector.opensearch.sink.RestClientFactory, org.apache.flink.connector.opensearch.sink.BulkResponseInspector)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchWriter.java:113) |
| Constructor <org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchDynamicSink.java:69) |
| Constructor <org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchDynamicSink.java:70) |
| Constructor <org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchDynamicSink.java:71) |
| Constructor <org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchDynamicSink.java:72) |
| Constructor <org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat, org.apache.flink.connector.opensearch.table.OpensearchConfiguration, java.util.List, org.apache.flink.table.types.DataType, java.lang.String, java.time.ZoneId)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchDynamicSink.java:73) |
| Constructor <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearchEmitter.java:56) |
| Constructor <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearchEmitter.java:57) |
| Constructor <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearchEmitter.java:58) |
| Constructor <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator, org.apache.flink.api.common.serialization.SerializationSchema, org.opensearch.common.xcontent.XContentType, java.util.function.Function)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (RowOpensearchEmitter.java:59) |
| Field <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.failureHandler> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (DefaultBulkResponseInspector.java:0) |
| Method <org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest, org.opensearch.action.bulk.BulkResponse)> calls method <org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable, java.lang.Throwable)> in (DefaultBulkResponseInspector.java:68) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSink.getBulkResponseInspectorFactory()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (OpensearchSink.java:0) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSink.getDeliveryGuarantee()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (OpensearchSink.java:0) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.build()> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:339) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.build()> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:340) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.buildNetworkClientConfig()> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:362) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:194) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:195) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:198) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:200) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushInterval(long)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:172) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushMaxActions(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:143) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushMaxSizeMb(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:158) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkResponseInspectorFactory(org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:329) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionPassword(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:227) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionPathPrefix(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:239) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionRequestTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:252) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:264) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionUsername(java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:215) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:131) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:128) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.InstantiationUtil.isSerializable(java.lang.Object)> in (OpensearchSinkBuilder.java:99) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:97) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:98) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setFailureHandler(org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:314) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setHosts([Lorg.apache.http.HttpHost;)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:114) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setHosts([Lorg.apache.http.HttpHost;)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:115) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setRestClientFactory(org.apache.flink.connector.opensearch.sink.RestClientFactory)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchSinkBuilder.java:302) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setSocketTimeout(int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (OpensearchSinkBuilder.java:277) |
| Method <org.apache.flink.connector.opensearch.sink.OpensearchWriter.blockingFlushAllActions()> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (OpensearchWriter.java:0) |
| Method <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter$1.getMetricGroup()> calls constructor <org.apache.flink.metrics.groups.UnregisteredMetricsGroup.<init>()> in (RowOpensearchEmitter.java:69) |
| Method <org.apache.flink.connector.opensearch.table.RowOpensearchEmitter$1.getUserCodeClassLoader()> calls method <org.apache.flink.util.SimpleUserCodeClassLoader.create(java.lang.ClassLoader)> in (RowOpensearchEmitter.java:74) |
