Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-7415][Cassandra Connector] Add comments for cassandra-connector test classes #4519

Closed
wants to merge 4 commits into from
Closed

[FLINK-7415][Cassandra Connector] Add comments for cassandra-connector test classes #4519

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
03e1e4a
add comments for BatchExample.java
yew1eb Aug 10, 2017
33ad86b
add comments for CassandraPojoSinkExample.java
yew1eb Aug 10, 2017
3b455b3
add comments for CassandraTupleSinkExample.java
yew1eb Aug 10, 2017
74f13d3
add comments for CassandraTupleWriteAheadSinkExample.java
yew1eb Aug 10, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
add comments for CassandraTupleWriteAheadSinkExample.java
  • Loading branch information
@yew1eb
yew1eb committed Aug 10, 2017
commit 74f13d3d4f54a41def02461160e0229b843567b6
3 changes: 2 additions & 1 deletion ...che/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,8 @@
/**
* This is an example showing the to use the Cassandra Sink (with write-ahead log) in the Streaming API.
*
* <p>The example assumes that a table exists in a local cassandra database, according to the following query:
* <p>The example assumes that a table exists in a local cassandra database, according to the following queries:
* CREATE KEYSPACE IF NOT EXISTS example WITH replication = {'class': 'SimpleStrategy', 'replication_factor': ‘1’};
* CREATE TABLE example.values (id text, count int, PRIMARY KEY(id));
*
* <p>Important things to note are that checkpointing is enabled, a StateBackend is set and the enableWriteAheadLog() call
Expand Down