You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This example uses [Apache Flink](../flink/flink-overview.md) to sink [HDInsight for Apache Kafka](/azure/hdinsight/kafka/apache-kafka-introduction) messages into [Azure Cosmos DB for Apache Cassandra](/azure/cosmos-db/cassandra/introduction)
13
+
This example uses [Apache Flink](../flink/flink-overview.md) to sink [HDInsight for Apache Kafka](/azure/hdinsight/kafka/apache-kafka-introduction) messages into [Azure Cosmos DB for Apache Cassandra](/azure/cosmos-db/cassandra/introduction).
14
14
15
15
This example is prominent when Engineers prefer real-time aggregated data for analysis. With access to historical aggregated data, you can build machine learning (ML) models to build insights or actions. You can also ingest IoT data into Apache Flink to aggregate data in real-time and store it in Apache Cassandra.
16
16
@@ -42,12 +42,12 @@ Get credentials uses it on Stream source code:
42
42
43
43
### Cloning repository of Azure Samples
44
44
45
-
Refer GitHub readme to download maven, clone this repository using `Azure-Samples/azure-cosmos-db-cassandra-java-getting-started.git` from
Go to maven project folder **azure-cosmos-db-cassandra-java-getting-started-main** and update the changes required for this example
50
+
Go to maven project folder **azure-cosmos-db-cassandra-java-getting-started-main** and update the changes required for this example.
51
51
52
52
**maven pom.xml**
53
53
```xml
@@ -429,7 +429,7 @@ public class CassandraDemo {
429
429
430
430
### Building the project
431
431
432
-
Run **mvn clean install** from azure-cosmos-db-cassandra-java-getting-started-main folder to build the project. This command generates cosmosdb-cassandra-examples.jar under target folder
432
+
Run **mvn clean install** from azure-cosmos-db-cassandra-java-getting-started-main folder to build the project. This command generates cosmosdb-cassandra-examples.jar under target folder.
@@ -464,7 +464,7 @@ bin/flink run -c com.azure.cosmosdb.cassandra.examples.UserProfile -j cosmosdb-c
464
464
465
465
## Sink Kafka Topics into Cosmos DB for Apache Cassandra
466
466
467
-
Run CassandraDemo class to sink Kafka topic into Cosmos DB for Apache Cassandra
467
+
Run CassandraDemo class to sink Kafka topic into Cosmos DB for Apache Cassandra.
468
468
469
469
```
470
470
bin/flink run -c com.azure.cosmosdb.cassandra.examples.CassandraDemo -j cosmosdb-cassandra-examples.jar
@@ -474,13 +474,13 @@ bin/flink run -c com.azure.cosmosdb.cassandra.examples.CassandraDemo -j cosmosdb
474
474
475
475
## Validate Apache Flink Job Submission
476
476
477
-
Check job on Flink Web UI on HDInsight on AKS Cluster
477
+
Check job on Flink Web UI on HDInsight on AKS Cluster.
478
478
479
479
:::image type="content" source="./media/cosmos-db-for-apache-cassandra/check-output-on-flink-ui.png" alt-text="Screenshot showing how to check the job on HDInsight on AKS Flink UI." lightbox="./media/cosmos-db-for-apache-cassandra/check-output-on-flink-ui.png":::
* Apache, Apache Kafka, Kafka, Apache Flink, Flink, Apache Cassandra, Cassandra and associated open source project names are [trademarks](../trademarks.md) of the [Apache Software Foundation](https://www.apache.org/) (ASF).
552
+
* Apache, Apache Kafka, Kafka, Apache Flink, Flink, Apache Cassandra, Cassandra, and associated open source project names are [trademarks](../trademarks.md) of the [Apache Software Foundation](https://www.apache.org/) (ASF).
0 commit comments