Functions — github.com/aws-samples/amazon-managed-service-for-apache-flink-examples

hub / github.com/aws-samples/amazon-managed-service-for-apache-flink-examples / functions

Functions544 in github.com/aws-samples/amazon-managed-service-for-apache-flink-examples

⨍ Functions 544◇ Types & classes 133↳ Endpoints 3

Methodmain

(String[] args)

java/Iceberg/IcebergDataStreamSource/src/main/java/com/amazonaws/services/msf/StreamingJob.java:60

Methodmain

(String[] args)

java/Iceberg/S3TableSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:71

Methodmain

(String[] args)

java/Iceberg/IcebergDataStreamSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:67

Methodmain

(String[] args)

java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/KafkaStreamingJob.java:89

Methodmain

(String[] args)

java/SQSSink/src/main/java/com/amazonaws/services/msf/SQSStreamingJob.java:62

Methodmain

(String[] args)

java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/BasicTableJob.java:46

Methodmain

(String[] args)

java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/StreamingJob.java:70

Methodmain

(String[] args)

java/S3ParquetSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:74

Methodmain

(String[] args)

java/S3ParquetSource/src/main/java/com/amazonaws/services/msf/S3ParquetToKinesisJob.java:78

Methodmain

(String[] args)

java/FlinkCDC/FlinkCDCSQLServerSource/src/main/java/com/amazonaws/services/msf/FlinkCDCSqlServer2JdbcJob.java:44

Methodmain

(String[] args)

java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/FirehoseStreamingJob.java:63

Methodmain

(String[] args)

java/AsyncIO/src/main/java/com/amazonaws/services/msf/RetriesFlinkJob.java:47

Methodmain

(String[] args)

java/GettingStarted/src/main/java/com/amazonaws/services/msf/BasicStreamingJob.java:61

Methodmain

(String[] args)

java/KafkaConfigProviders/Kafka-SASL_SSL-ConfigProviders/src/main/java/com/amazonaws/services/msf/StreamingJob.java:148

Methodmain

(String[] args)

java/KafkaConfigProviders/Kafka-mTLS-Keystore-Sql-ConfigProviders/src/main/java/com/amazonaws/services/msf/StreamingJob.java:59

Methodmain

(String[] args)

java/KafkaConfigProviders/Kafka-mTLS-Keystore-ConfigProviders/src/main/java/com/amazonaws/services/msf/StreamingJob.java:105

Methodmain

(String[] args)

java/SideOutputs/src/main/java/com/amazonaws/services/msf/SideOutputsFlinkJob.java:59

Methodmain

(String[] args)

java/JdbcSink/src/main/java/com/amazonaws/services/msf/JdbcSinkJob.java:131

Methodmain

(String[] args)

java/FetchSecrets/src/main/java/com/amazonaws/services/msf/FetchSecretsJob.java:126

Methodmain

(String[] args)

java/PrometheusSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:95

Methodmain

(String[] args)

java/AvroGlueSchemaRegistryKinesis/src/main/java/com/amazonaws/services/msf/StreamingJob.java:145

Methodmain

(String[] args)

java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/CustomTypeInfoJob.java:68

Methodmap

(Long aLong)

java/S3AvroSink/src/main/java/com/amazonaws/services/msf/datagen/StockPriceGeneratorFunction.java:12

Methodmap

(Long aLong)

java/CustomMetrics/src/main/java/com/amazonaws/services/msf/SpeedRecordGeneratorFunction.java:9

Methodmap

(Long sequence)

java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/source/StockPriceGeneratorFunction.java:18

Methodmap

(GenericRecord genericRecord)

java/Iceberg/IcebergDataStreamSink/src/main/java/com/amazonaws/services/msf/iceberg/AvroGenericRecordToRowDataMapper.java:21

Methodmap

Generates a random trade

java/Iceberg/IcebergDataStreamSink/src/main/java/com/amazonaws/services/msf/datagen/AvroGenericStockTradeGeneratorFunction.java:30

Methodmap

(Long aLong)

java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPriceGeneratorFunction.java:12

Methodmap

(Long aLong)

java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPriceGeneratorFunction.java:12

Methodmap

(Long value)

java/JdbcSink/src/main/java/com/amazonaws/services/msf/domain/StockPriceGeneratorFunction.java:23

Methodmap

(TemperatureSample value)

java/PrometheusSink/src/main/java/com/amazonaws/services/msf/map/TemperatureSampleToPrometheusTimeSeriesMapper.java:11

Methodmap

(Long value)

java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/datagen/VehicleEventGeneratorFunction.java:18

MethodnestedPojoSerializeAndDeserializeWithoutKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:218

MethodnestedPojosShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:211

MethodonFailure

(Throwable t)

java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/KplAggregatingProducer.java:173

MethodonSuccess

(UserRecordResult result)

java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/KplAggregatingProducer.java:167

Methodopen

(self, runtime_context: RuntimeContext)

python/DatastreamKafkaConnector/datastream-kafka-connector-example.py:51

Methodopen

(DeserializationSchema.InitializationContext context)

java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/deaggregation/KinesisDeaggregatingDeserializationSchemaWrapper.java:32

Methodopen

(Configuration config)

java/CustomMetrics/src/main/java/com/amazonaws/services/msf/MetricEmittingMapperFunction.java:22

Methodopen

(OpenContext openContext)

java/S3ParquetSource/src/main/java/com/amazonaws/services/msf/JsonConverter.java:24

Methodopen

Instantiate the connection to an async client here to use within asyncInvoke

java/AsyncIO/src/main/java/com/amazonaws/services/msf/ProcessingFunction.java:40

Methodpartition

(T record, byte[] key, byte[] value, String targetTopic, int[] partitions)

java/AvroGlueSchemaRegistryKafka/producer/src/main/java/com/amazonaws/services/msf/kafka/KeyHashKafkaPartitioner.java:16

MethodpojoWithCollectionShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:75

MethodpojoWithInstantShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:101

MethodpojoWithInstantShouldSerializeAndDeserializeWithoutKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:107

MethodpojoWithZonedDateTimeShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:156

Methodprocess

(String key, Context context, Iterable<Double> average

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/WindowStreamingJob.java:156

MethodprocessElement

(Tuple2<IncomingEvent, ProcessingOutcome> value, Context ctx, Collector<IncomingEv

java/SideOutputs/src/main/java/com/amazonaws/services/msf/SideOutputsFlinkJob.java:81

Methodquery

Returns the SQL of the PreparedStatement @return SQL

java/JdbcSink/src/main/java/com/amazonaws/services/msf/jdbc/StockPriceUpsertQueryStatement.java:74

FunctionremovePrefix

(str: string, prefix: string)

infrastructure/AutoScaling/cdk/lib/kda-autoscaling-stack.ts:12

MethodserializationShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/VehicleEventSerializationTest.java:19

MethodserializationShouldNotFallbackToKryo

()

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/AggregateVehicleEventSerializationTest.java:18

MethodsetAverageSensorData

(Map<String, Long> averageSensorData)

java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/AggregateVehicleEvent.java:71

MethodsetCountDistinctWarnings

(int countDistinctWarnings)

java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/AggregateVehicleEvent.java:79

MethodsetDuration

(Duration duration)

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:140

MethodsetElements

(List<String> elements)

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:53

MethodsetEventTime

(String eventTime)

java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:19

MethodsetEventTime

(String eventTime)

java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/model/StockPrice.java:18

MethodsetEventTime

(Timestamp eventTime)

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/StockPrice.java:24

MethodsetEventTime

(Timestamp eventTime)

java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:24

MethodsetEventTime

(String eventTime)

java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:19

MethodsetEventTime

(String eventTime)

java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:27

MethodsetEventTime

(Timestamp eventTime)

java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:24

MethodsetEventTime

(Timestamp eventTime)

java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:24

MethodsetEventTime

(Timestamp eventTime)

java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:24

MethodsetFieldOne

(String fieldOne)

java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:41

MethodsetFieldTwo

(String fieldTwo)

java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:49

MethodsetLocalDateTime

(LocalDateTime localDateTime)

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:149

MethodsetMapOfElements

(Map<String, Integer> mapOfElements)

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:61

MethodsetMinPrice

(Double minPrice)

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/AggregatedStockPrice.java:40

MethodsetPartitionKey

(String partitionKey)

java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:23

MethodsetPrice

(float price)

java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:35

MethodsetPrice

(double price)

java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/model/StockPrice.java:34

MethodsetPrice

(Double price)

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/StockPrice.java:40

MethodsetPrice

(Double price)

java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:40

MethodsetPrice

(float price)

java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:35

MethodsetPrice

(Float price)

java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:39

MethodsetPrice

(float price)

java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:43

MethodsetPrice

(double price)

java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:40

MethodsetPrice

(Double price)

java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:40

MethodsetPrice

(Double price)

java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:40

MethodsetPrice

(BigDecimal price)

java/JdbcSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:42

MethodsetPrice

(double price)

java/FetchSecrets/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:36

MethodsetRoomId

(String roomId)

java/PrometheusSink/src/main/java/com/amazonaws/services/msf/domain/TemperatureSample.java:23

MethodsetSensorData

(Map<String, Long> sensorData)

java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/VehicleEvent.java:106

MethodsetSetOfElements

(Set<String> setOfElements)

java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:69

MethodsetSortKey

(String sortKey)

java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:33

MethodsetSymbol

(String symbol)

java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:31

MethodsetSymbol

(String symbol)

java/JdbcSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:26

MethodsetSymbol

(String symbol)

java/FetchSecrets/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:20

MethodsetTicker

(String ticker)

java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:27

MethodsetTicker

(String ticker)

java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/model/StockPrice.java:26

MethodsetTicker

(String ticker)

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/StockPrice.java:32

MethodsetTicker

(String ticker)

java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/AggregatedStockPrice.java:24

MethodsetTicker

(String ticker)

java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:32

MethodsetTicker

(String ticker)

java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:27

MethodsetTicker

(String ticker)

java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:35

MethodsetTicker

(String ticker)

java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:32

MethodsetTicker

(String ticker)

java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:32

MethodsetTicker

(String ticker)

java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:32

← previous next →401–500 of 544, ranked by callers