MCPcopy Create free account

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
MethodStockPrice
()
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:13
MethodStockPrice
(String eventTime, String ticker, double price)
java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/model/StockPrice.java:8
MethodStockPrice
()
java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/StockPrice.java:11
MethodStockPrice
()
java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:11
MethodStockPrice
()
java/FlinkDataGenerator/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:14
MethodStockPrice
()
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:9
MethodStockPrice
()
java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:15
MethodStockPrice
()
java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:11
MethodStockPrice
()
java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:11
MethodStockPrice
()
java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:11
MethodStockPrice
()
java/JdbcSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:14
MethodStockPrice
()
java/FetchSecrets/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:8
MethodStockPriceUpsertQueryStatement
Create an UPSERT stock price query statement for a given table name. Note that, while the values are passed at runtime, the table name must be defined
java/JdbcSink/src/main/java/com/amazonaws/services/msf/jdbc/StockPriceUpsertQueryStatement.java:65
MethodTemperatureSample
(String roomId, String sensorId, long timestamp, double temperature)
java/PrometheusSink/src/main/java/com/amazonaws/services/msf/domain/TemperatureSample.java:9
MethodVehicleEvent
()
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/VehicleEvent.java:76
MethodareKerberosCredentialsValid
( UserGroupInformation ugi, boolean useTicketCache)
java/Iceberg/IcebergSQLSink/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:47
MethodareKerberosCredentialsValid
( UserGroupInformation ugi, boolean useTicketCache)
java/S3ParquetSource/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:47
Functionask_bedrock_for_fun_fact
(a_number)
python/PythonDependencies/main.py:123
MethodasyncInvoke
(IncomingEvent incomingEvent, ResultFuture<ProcessedEvent> resultFuture)
java/AsyncIO/src/main/java/com/amazonaws/services/msf/ProcessingFunction.java:53
Functioncelsius_to_fahrenheit
(celsius)
python/UDF/main.py:104
Methodconstructor
(scope: Construct, id: string, props?: cdk.StackProps)
infrastructure/AutoScaling/cdk/lib/kda-autoscaling-stack.ts:33
Methodconstructor
(scope, id, props)
infrastructure/AutoScaling/cdk/lib/kda-autoscaling-stack.js:7
MethodcreateAccumulator
()
java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/WindowStreamingJob.java:125
MethodcreateConverter
()
java/S3AvroSource/src/main/java/com/amazonaws/services/msf/AvroSpecificRecordBulkFormat.java:34
MethodcreateReusedAvroRecord
()
java/S3AvroSource/src/main/java/com/amazonaws/services/msf/AvroSpecificRecordBulkFormat.java:29
MethodcreateTypeInfo
(Type t, Map<String, TypeInformation<?>> genericParameters)
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/AggregateVehicleEvent.java:32
MethodcreateTypeInfo
(Type t, Map<String, TypeInformation<?>> genericParameters)
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/VehicleEvent.java:41
MethodcreateTypeInfo
(Type t, Map<String, TypeInformation<?>> genericParameters)
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/VehicleEvent.java:50
Methoddeserialize
(Record record, String stream, String shardId, Collector<T> output)
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/deaggregation/KinesisDeaggregatingDeserializationSchemaWrapper.java:37
Functiondeterminant
(element1, element2, element3, element4)
python/PackagedPythonDependencies/main.py:139
Methodequals
(Object o)
java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:47
Methodequals
(Object o)
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/AggregateVehicleEvent.java:83
MethodgenerateRecord
()
java/Iceberg/S3TableSink/src/test/java/com/amazonaws/services/msf/datagen/AvroGenericStockTradeGeneratorFunctionTest.java:12
MethodgetDuration
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:136
MethodgetElements
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:49
MethodgetEventTime
()
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:15
MethodgetEventTime
()
java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:20
MethodgetEventTime
()
java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:15
MethodgetEventTime
()
java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:23
MethodgetEventTime
()
java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:20
MethodgetEventTime
()
java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:20
MethodgetEventTime
()
java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:20
MethodgetEventType
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/ChangeEvent.java:20
MethodgetFieldOne
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:37
MethodgetFieldTwo
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:45
MethodgetHadoopConfiguration
( org.apache.flink.configuration.Configuration flinkConfiguration)
python/IcebergSink/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:10
MethodgetHadoopConfiguration
This method has been re-implemented to always return a org.apache.hadoop.conf.Configuration
java/Iceberg/IcebergSQLSink/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:35
MethodgetHadoopConfiguration
This method has been re-implemented to always return a org.apache.hadoop.conf.Configuration
java/S3ParquetSource/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:35
MethodgetLocalDateTime
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:145
MethodgetMapOfElements
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:57
MethodgetMessage
()
java/AsyncIO/src/main/java/com/amazonaws/services/msf/ProcessedEvent.java:19
MethodgetNewItem
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/ChangeEvent.java:36
MethodgetOldItem
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/ChangeEvent.java:28
MethodgetPartitionKey
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:16
MethodgetPrice
()
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:31
MethodgetPrice
()
java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:36
MethodgetPrice
()
java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:31
MethodgetPrice
()
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:35
MethodgetPrice
()
java/KafkaConnectors/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:39
MethodgetPrice
()
java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:36
MethodgetPrice
()
java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:36
MethodgetPrice
()
java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:36
MethodgetProducedType
()
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/deaggregation/KinesisDeaggregatingDeserializationSchemaWrapper.java:52
MethodgetProducedType
()
java/S3AvroSource/src/main/java/com/amazonaws/services/msf/AvroSpecificRecordBulkFormat.java:39
MethodgetProducedType
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/ChangeEventDeserializationSchema.java:41
MethodgetResult
(Double accumulator)
java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/WindowStreamingJob.java:137
MethodgetSetOfElements
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:65
MethodgetSortKey
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/DdbTableItem.java:27
MethodgetSymbol
()
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:27
MethodgetTicker
()
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/model/StockPrice.java:23
MethodgetTicker
()
java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/AggregatedStockPrice.java:20
MethodgetTicker
()
java/S3Sink/src/main/java/com/amazonaws/services/msf/StockPrice.java:28
MethodgetTicker
()
java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/Stock.java:23
MethodgetTicker
()
java/SQSSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:28
MethodgetTicker
()
java/GettingStartedTable/src/main/java/com/amazonaws/services/msf/StockPrice.java:28
MethodgetTicker
()
java/KinesisFirehoseSink/src/main/java/com/amazonaws/services/msf/StockPrice.java:28
MethodgetTimestamp
()
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:19
MethodgetTimestamp
()
java/DynamoDBStreamSource/src/main/java/com/amazonaws/services/msf/ChangeEvent.java:12
MethodgetVolumes
()
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/domain/StockPrice.java:43
MethodgetZonedDateTime
()
java/Serialization/CustomTypeInfo/src/test/java/com/amazonaws/services/msf/domain/MoreKryoSerializationExamplesTest.java:128
Functionhandler
(event, context)
infrastructure/AutoScaling/cdk/resources/scaling/scaling.py:58
MethodhashCode
()
java/Serialization/CustomTypeInfo/src/main/java/com/amazonaws/services/msf/domain/AggregateVehicleEvent.java:95
MethodisAboveSpeedLimit
(SpeedRecord value)
java/CustomMetrics/src/main/java/com/amazonaws/services/msf/SpeedLimitFilter.java:7
MethodisLocal
(StreamExecutionEnvironment env)
java/PrometheusSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:37
MethodisMaxHadoopVersion
Checks if the Hadoop dependency is at most the given version.
java/Iceberg/IcebergSQLSink/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:98
MethodisMaxHadoopVersion
Checks if the Hadoop dependency is at most the given version.
java/S3ParquetSource/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:98
MethodisMinHadoopVersion
Checks if the Hadoop dependency is at least the given version.
java/Iceberg/IcebergSQLSink/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:87
MethodisMinHadoopVersion
Checks if the Hadoop dependency is at least the given version.
java/S3ParquetSource/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java:87
Methodmain
(String[] args)
java/AvroGlueSchemaRegistryKafka/producer/src/main/java/com/amazonaws/services/msf/StreamingJob.java:109
Methodmain
(String[] args)
java/AvroGlueSchemaRegistryKafka/consumer/src/main/java/com/amazonaws/services/msf/StreamingJob.java:80
Methodmain
(String[] args)
java/KinesisSourceDeaggregation/flink-app/src/main/java/com/amazonaws/services/msf/StreamingJob.java:73
Methodmain
(String[] args)
java/KinesisSourceDeaggregation/kpl-producer/src/main/java/com/amazonaws/services/kds/producer/KplAggregatingProducer.java:47
Methodmain
(String[] args)
java/Windowing/src/main/java/com/amazonaws/services/msf/windowing/WindowStreamingJob.java:56
Methodmain
(String[] args)
java/S3AvroSource/src/main/java/com/amazonaws/services/msf/StreamingJob.java:79
Methodmain
(String[] args)
java/S3Sink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:75
Methodmain
(String[] args)
java/KinesisConnectors/src/main/java/com/amazonaws/services/msf/StreamingJob.java:69
Methodmain
(String[] args)
java/FlinkDataGenerator/src/main/java/com/amazonaws/services/msf/DataGeneratorJob.java:146
Methodmain
(String[] args)
java/S3AvroSink/src/main/java/com/amazonaws/services/msf/StreamingJob.java:74
Methodmain
(String[] args)
java/CustomMetrics/src/main/java/com/amazonaws/services/msf/RecordCountJob.java:45
Methodmain
(String[] args)
java/Iceberg/IcebergSQLSink/src/main/java/com/amazonaws/services/msf/IcebergSQLSinkJob.java:114
← previousnext →301–400 of 544, ranked by callers