Skip to content

Instantly share code, notes, and snippets.

@dbergqvist

dbergqvist/MultiRangeScan.java

Created October 21, 2019 15:11
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dbergqvist/66c35e58f2461eff513d98d85bac7009 to your computer and use it in GitHub Desktop.
Save dbergqvist/66c35e58f2461eff513d98d85bac7009 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
MultiRangeScan.java
Query query = Query.create(TABLE_ID);
for (String busLine : MANHATTAN_BUS_LINES) {
query.range("MTA/" + busLine + "/1496275200000", "MTA/" + busLine + "/1496275200001");
}
query.filter(FILTERS
.interleave()
.filter(FILTERS.qualifier().exactMatch(LAT_COLUMN_NAME_STRING))
.filter(FILTERS.qualifier().exactMatch(LONG_COLUMN_NAME_STRING)));
ServerStream<Row> rows = dataClient.readRows(query);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment