{"action":"created","comment":{"url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/comments/57918415","id":57918415,"diff_hunk":"@@ -1,7 +1,59 @@\n-= Spring Cloud Stream Cassandra Sink\n+//tag::ref-doc[]\n+= Cassandra Sink (`cassandra`)\n+\n+The Cassandra sink writes into a Cassandra table. Here is a simple example\n+\n+  dataflow:>stream create cassandrastream --definition \"http --server.port=8888 --spring.cloud.stream.bindings.output.contentType='application/json' | cassandra --ingestQuery='insert into book (id, isbn, title, author) values (uuid(), ?, ?, ?)' --spring.cassandra.keyspace=clouddata\" --deploy\n+\n+Create a keyspace and a `book` table in Cassandra using:\n+\n+[source,text]\n+----\n+CREATE KEYSPACE clouddata WITH REPLICATION = { 'class' : 'org.apache.cassandra.locator.SimpleStrategy', 'replication_factor': '1' } AND DURABLE_WRITES = true;\n+USE clouddata;\n+CREATE TABLE book  (\n+    id          uuid PRIMARY KEY,\n+    isbn        text,\n+    author      text,\n+    title       text\n+);\n+----\n+\n+You can then send data to this stream via\n+\n+  dataflow:>http post --contentType 'application/json' --data '{\"isbn\": \"1599869772\", \"title\": \"The Art of War\", \"author\": \"Sun Tzu\"}' --target http://localhost:8888/\n+  > POST (application/json;charset=UTF-8) http://localhost:8888/ {\"isbn\": \"1599869772\", \"title\": \"The Art of War\", \"author\": \"Sun Tzu\"}\n+  > 202 ACCEPTED\n+\n+and see the table contents using the CQL\n+\n+  SELECT * FROM clouddata.book;\n \n This module writes the content of each message it receives to Cassandra.\n \n+=== Options\n+\n+The **$$cassandra$$** $$sink$$ has the following options:\n+\n+$$compressionType$$:: $$the compression to use for the transport$$ *($$CompressionType$$, default: `NONE`, possible values: `NONE,SNAPPY`)*\n+$$consistencyLevel$$:: $$the consistencyLevel option of WriteOptions$$ *($$ConsistencyLevel$$, no default, possible values: `ANY,ONE,TWO,THREE,QUOROM,LOCAL_QUOROM,EACH_QUOROM,ALL,LOCAL_ONE,SERIAL,LOCAL_SERIAL`)*\n+$$spring.cassandra.contactPoints$$:: $$the comma-delimited string of the hosts to connect to Cassandra$$ *($$String$$, default: `localhost`)*\n+$$entityBasePackages$$:: $$the base packages to scan for entities annotated with Table annotations$$ *($$String[]$$, default: `[]`)*\n+$$ingestQuery$$:: $$the ingest Cassandra query$$ *($$String$$, no default)*\n+$$spring.cassandra.initScript$$:: $$the path to file with CQL scripts (delimited by ';') to initialize keyspace schema$$ *($$String$$, no default)*\n+$$spring.cassandra.keyspace$$:: $$the keyspace name to connect to$$ *($$String$$, default: `<stream name>`)*\n+$$metricsEnabled$$:: $$enable/disable metrics collection for the created cluster$$ *($$boolean$$, default: `true`)*\n+$$spring.cassandra.password$$:: $$the password for connection$$ *($$String$$, no default)*\n+$$spring.cassandra.port$$:: $$the port to use to connect to the Cassandra host$$ *($$int$$, default: `9042`)*\n+$$queryType$$:: $$the queryType for Cassandra Sink$$ *($$Type$$, default: `INSERT`, possible values: `INSERT,UPDATE,DELETE,STATEMENT`)*\n+$$retryPolicy$$:: $$the retryPolicy  option of WriteOptions$$ *($$RetryPolicy$$, no default, possible values: `DEFAULT,DOWNGRADING_CONSISTENCY,FALLTHROUGH,LOGGING`)*\n+$$statementExpression$$:: $$the expression in Cassandra query DSL style$$ *($$String$$, no default)*\n+$$spring.cassandra.schemaAction$$:: $$schema action to perform$$ *($$SchemaAction$$, default: `NONE`, possible values: `CREATE,NONE,RECREATE,RECREATE_DROP_UNUSED`)*\n+$$ttl$$:: $$the time-to-live option of WriteOptions$$ *($$int$$, default: `0`)*\n+$$spring.cassandra.username$$:: $$the username for connection$$ *($$String$$, no default)*\n+\n+//end::ref-doc[]\n+\n == Requirements","path":"cassandra-sink/README.adoc","position":58,"original_position":58,"commit_id":"7fbd08d17a1add69032b9909e307eb8a782c73fd","original_commit_id":"7fbd08d17a1add69032b9909e307eb8a782c73fd","user":{"login":"ericbottard","id":313494,"avatar_url":"https://avatars.githubusercontent.com/u/313494?v=3","gravatar_id":"","url":"https://api.github.com/users/ericbottard","html_url":"https://github.com/ericbottard","followers_url":"https://api.github.com/users/ericbottard/followers","following_url":"https://api.github.com/users/ericbottard/following{/other_user}","gists_url":"https://api.github.com/users/ericbottard/gists{/gist_id}","starred_url":"https://api.github.com/users/ericbottard/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ericbottard/subscriptions","organizations_url":"https://api.github.com/users/ericbottard/orgs","repos_url":"https://api.github.com/users/ericbottard/repos","events_url":"https://api.github.com/users/ericbottard/events{/privacy}","received_events_url":"https://api.github.com/users/ericbottard/received_events","type":"User","site_admin":false},"body":"Requirements sections should be removed. We decided to only keep\r\n* intro text\r\n* Options (level 2)\r\n* any other relevant examples, explanations, etc (without references to dataflow)\r\n* Building (level 2, not in ref-doc)\r\n* Running (level 2, not in ref-doc)","created_at":"2016-03-30T16:22:14Z","updated_at":"2016-03-30T16:22:14Z","html_url":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1#discussion_r57918415","pull_request_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1","_links":{"self":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/comments/57918415"},"html":{"href":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1#discussion_r57918415"},"pull_request":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1"}}},"pull_request":{"url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1","id":64646583,"html_url":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1","diff_url":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1.diff","patch_url":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1.patch","issue_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/1","number":1,"state":"open","locked":false,"title":"Updates to cassandra, counter and field-value-counter docs","user":{"login":"sabbyanandan","id":1562654,"avatar_url":"https://avatars.githubusercontent.com/u/1562654?v=3","gravatar_id":"","url":"https://api.github.com/users/sabbyanandan","html_url":"https://github.com/sabbyanandan","followers_url":"https://api.github.com/users/sabbyanandan/followers","following_url":"https://api.github.com/users/sabbyanandan/following{/other_user}","gists_url":"https://api.github.com/users/sabbyanandan/gists{/gist_id}","starred_url":"https://api.github.com/users/sabbyanandan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sabbyanandan/subscriptions","organizations_url":"https://api.github.com/users/sabbyanandan/orgs","repos_url":"https://api.github.com/users/sabbyanandan/repos","events_url":"https://api.github.com/users/sabbyanandan/events{/privacy}","received_events_url":"https://api.github.com/users/sabbyanandan/received_events","type":"User","site_admin":false},"body":"_I had to rebase so it includes all the changes since your last push to your fork_","created_at":"2016-03-30T15:25:38Z","updated_at":"2016-03-30T16:22:14Z","closed_at":null,"merged_at":null,"merge_commit_sha":"cc5eff1015716d9af1b58639e3ed73a9a08eee64","assignee":null,"milestone":null,"commits_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1/commits","review_comments_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1/comments","review_comment_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/comments{/number}","comments_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/1/comments","statuses_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/statuses/7fbd08d17a1add69032b9909e307eb8a782c73fd","head":{"label":"sabbyanandan:sabby-issue_200","ref":"sabby-issue_200","sha":"7fbd08d17a1add69032b9909e307eb8a782c73fd","user":{"login":"sabbyanandan","id":1562654,"avatar_url":"https://avatars.githubusercontent.com/u/1562654?v=3","gravatar_id":"","url":"https://api.github.com/users/sabbyanandan","html_url":"https://github.com/sabbyanandan","followers_url":"https://api.github.com/users/sabbyanandan/followers","following_url":"https://api.github.com/users/sabbyanandan/following{/other_user}","gists_url":"https://api.github.com/users/sabbyanandan/gists{/gist_id}","starred_url":"https://api.github.com/users/sabbyanandan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sabbyanandan/subscriptions","organizations_url":"https://api.github.com/users/sabbyanandan/orgs","repos_url":"https://api.github.com/users/sabbyanandan/repos","events_url":"https://api.github.com/users/sabbyanandan/events{/privacy}","received_events_url":"https://api.github.com/users/sabbyanandan/received_events","type":"User","site_admin":false},"repo":{"id":47435943,"name":"spring-cloud-stream-modules","full_name":"sabbyanandan/spring-cloud-stream-modules","owner":{"login":"sabbyanandan","id":1562654,"avatar_url":"https://avatars.githubusercontent.com/u/1562654?v=3","gravatar_id":"","url":"https://api.github.com/users/sabbyanandan","html_url":"https://github.com/sabbyanandan","followers_url":"https://api.github.com/users/sabbyanandan/followers","following_url":"https://api.github.com/users/sabbyanandan/following{/other_user}","gists_url":"https://api.github.com/users/sabbyanandan/gists{/gist_id}","starred_url":"https://api.github.com/users/sabbyanandan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/sabbyanandan/subscriptions","organizations_url":"https://api.github.com/users/sabbyanandan/orgs","repos_url":"https://api.github.com/users/sabbyanandan/repos","events_url":"https://api.github.com/users/sabbyanandan/events{/privacy}","received_events_url":"https://api.github.com/users/sabbyanandan/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/sabbyanandan/spring-cloud-stream-modules","description":"","fork":true,"url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules","forks_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/forks","keys_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/keys{/key_id}","collaborators_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/teams","hooks_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/hooks","issue_events_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/issues/events{/number}","events_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/events","assignees_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/assignees{/user}","branches_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/branches{/branch}","tags_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/tags","blobs_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/git/refs{/sha}","trees_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/git/trees{/sha}","statuses_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/statuses/{sha}","languages_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/languages","stargazers_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/stargazers","contributors_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/contributors","subscribers_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/subscribers","subscription_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/subscription","commits_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/commits{/sha}","git_commits_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/git/commits{/sha}","comments_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/comments{/number}","issue_comment_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/issues/comments{/number}","contents_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/contents/{+path}","compare_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/compare/{base}...{head}","merges_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/merges","archive_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/downloads","issues_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/issues{/number}","pulls_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/pulls{/number}","milestones_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/milestones{/number}","notifications_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/labels{/name}","releases_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/releases{/id}","deployments_url":"https://api.github.com/repos/sabbyanandan/spring-cloud-stream-modules/deployments","created_at":"2015-12-05T00:38:03Z","updated_at":"2016-03-30T14:18:22Z","pushed_at":"2016-03-30T15:21:46Z","git_url":"git://github.com/sabbyanandan/spring-cloud-stream-modules.git","ssh_url":"git@github.com:sabbyanandan/spring-cloud-stream-modules.git","clone_url":"https://github.com/sabbyanandan/spring-cloud-stream-modules.git","svn_url":"https://github.com/sabbyanandan/spring-cloud-stream-modules","homepage":null,"size":1573,"stargazers_count":0,"watchers_count":0,"language":"Java","has_issues":false,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":0,"mirror_url":null,"open_issues_count":0,"forks":0,"open_issues":0,"watchers":0,"default_branch":"master"}},"base":{"label":"ericbottard:master","ref":"master","sha":"56bc239830e5b0f44a63c3f98e21cd307f343bcf","user":{"login":"ericbottard","id":313494,"avatar_url":"https://avatars.githubusercontent.com/u/313494?v=3","gravatar_id":"","url":"https://api.github.com/users/ericbottard","html_url":"https://github.com/ericbottard","followers_url":"https://api.github.com/users/ericbottard/followers","following_url":"https://api.github.com/users/ericbottard/following{/other_user}","gists_url":"https://api.github.com/users/ericbottard/gists{/gist_id}","starred_url":"https://api.github.com/users/ericbottard/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ericbottard/subscriptions","organizations_url":"https://api.github.com/users/ericbottard/orgs","repos_url":"https://api.github.com/users/ericbottard/repos","events_url":"https://api.github.com/users/ericbottard/events{/privacy}","received_events_url":"https://api.github.com/users/ericbottard/received_events","type":"User","site_admin":false},"repo":{"id":40111058,"name":"spring-cloud-stream-modules","full_name":"ericbottard/spring-cloud-stream-modules","owner":{"login":"ericbottard","id":313494,"avatar_url":"https://avatars.githubusercontent.com/u/313494?v=3","gravatar_id":"","url":"https://api.github.com/users/ericbottard","html_url":"https://github.com/ericbottard","followers_url":"https://api.github.com/users/ericbottard/followers","following_url":"https://api.github.com/users/ericbottard/following{/other_user}","gists_url":"https://api.github.com/users/ericbottard/gists{/gist_id}","starred_url":"https://api.github.com/users/ericbottard/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ericbottard/subscriptions","organizations_url":"https://api.github.com/users/ericbottard/orgs","repos_url":"https://api.github.com/users/ericbottard/repos","events_url":"https://api.github.com/users/ericbottard/events{/privacy}","received_events_url":"https://api.github.com/users/ericbottard/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/ericbottard/spring-cloud-stream-modules","description":"","fork":true,"url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules","forks_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/forks","keys_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/keys{/key_id}","collaborators_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/teams","hooks_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/hooks","issue_events_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/events{/number}","events_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/events","assignees_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/assignees{/user}","branches_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/branches{/branch}","tags_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/tags","blobs_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/git/refs{/sha}","trees_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/git/trees{/sha}","statuses_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/statuses/{sha}","languages_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/languages","stargazers_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/stargazers","contributors_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/contributors","subscribers_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/subscribers","subscription_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/subscription","commits_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/commits{/sha}","git_commits_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/git/commits{/sha}","comments_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/comments{/number}","issue_comment_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/comments{/number}","contents_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/contents/{+path}","compare_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/compare/{base}...{head}","merges_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/merges","archive_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/downloads","issues_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues{/number}","pulls_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls{/number}","milestones_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/milestones{/number}","notifications_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/labels{/name}","releases_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/releases{/id}","deployments_url":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/deployments","created_at":"2015-08-03T07:22:59Z","updated_at":"2015-08-03T07:22:59Z","pushed_at":"2016-03-30T15:25:38Z","git_url":"git://github.com/ericbottard/spring-cloud-stream-modules.git","ssh_url":"git@github.com:ericbottard/spring-cloud-stream-modules.git","clone_url":"https://github.com/ericbottard/spring-cloud-stream-modules.git","svn_url":"https://github.com/ericbottard/spring-cloud-stream-modules","homepage":null,"size":1077,"stargazers_count":0,"watchers_count":0,"language":"Java","has_issues":false,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":0,"mirror_url":null,"open_issues_count":1,"forks":0,"open_issues":1,"watchers":0,"default_branch":"master"}},"_links":{"self":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1"},"html":{"href":"https://github.com/ericbottard/spring-cloud-stream-modules/pull/1"},"issue":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/1"},"comments":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/issues/1/comments"},"review_comments":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1/comments"},"review_comment":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/pulls/1/commits"},"statuses":{"href":"https://api.github.com/repos/ericbottard/spring-cloud-stream-modules/statuses/7fbd08d17a1add69032b9909e307eb8a782c73fd"}}}}