Skip to content

Instantly share code, notes, and snippets.

View dbergqvist's full-sized avatar

Daniel Bergqvist dbergqvist

4 followers · 1 following
View GitHub Profile
@dbergqvist
dbergqvist / grantAccess.txt
Last active January 10, 2020 16:01
gcloud projects add-iam-policy-binding my-project --member user:alice@example.com --role roles/cloudsql.admin
@dbergqvist
dbergqvist / MultiRangeScan.java
Created October 21, 2019 15:11
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)));
@dbergqvist
dbergqvist / MultiRangeScanHBase.java
Created October 21, 2019 15:11
private static final String[] MANHATTAN_BUS_LINES = {"M1","M2","M3",...
List<RowRange> ranges = new ArrayList<>();
for (String busLine : MANHATTAN_BUS_LINES) {
ranges.add(
new RowRange(
Bytes.toBytes("MTA/" + busLine + "/1496275200000"), true,
Bytes.toBytes("MTA/" + busLine + "/1496275200001"), false));
}
Filter filter = new MultiRowRangeFilter(ranges);
@dbergqvist
dbergqvist / FiltersWest.java
Created October 21, 2019 15:10
.filter(FILTERS.qualifier().exactMatch("DestinationName"))
.filter(FILTERS.value().exactMatch("Select Bus Service Westside West End AV")))
@dbergqvist
dbergqvist / FiltersWestHBase.java
Created October 21, 2019 15:09
SingleColumnValueFilter valueFilter =
new SingleColumnValueFilter(
COLUMN_FAMILY_NAME,
Bytes.toBytes("DestinationName"),
CompareOp.EQUAL,
Bytes.toBytes("Select Bus Service Westside West End AV"));
@dbergqvist
dbergqvist / FiltersEast.java
Created October 21, 2019 15:09
Filters.ChainFilter chain = FILTERS
.chain()
.filter(FILTERS.limit().cellsPerColumn(1))
.filter(FILTERS.condition(
FILTERS.chain()
.filter(FILTERS.limit().cellsPerColumn(1))
.filter(FILTERS.qualifier().exactMatch("DestinationName"))
.filter(FILTERS.value().exactMatch("Select Bus Service Yorkville East End AV")))
.then(FILTERS
.interleave()
@dbergqvist
dbergqvist / FiltersEastHBase.java
Created October 21, 2019 15:08
Scan scan = new Scan();
SingleColumnValueFilter valueFilter =
new SingleColumnValueFilter(
COLUMN_FAMILY_NAME,
Bytes.toBytes("DestinationName"),
CompareOp.EQUAL,
Bytes.toBytes("Select Bus Service Yorkville East End AV"));
scan.setMaxVersions(1)
@dbergqvist
dbergqvist / ScanPartial.java
Created October 21, 2019 15:02
Query.create(TABLE_ID)
.prefix("MTA/M86-SBS/")
.filter(FILTERS.limit().cellsPerColumn(1))
@dbergqvist
dbergqvist / ScanHBasePartial.java
Created October 21, 2019 15:01
scan.withStartRow(Bytes.toBytes("MTA/M86-SBS/"))
.setRowPrefixFilter(Bytes.toBytes("MTA/M86-SBS/"));
//Optionally, reduce the result to receive one version per column
scan.setMaxVersions(1);
@dbergqvist
dbergqvist / Scan.java
Created October 21, 2019 14:59
Query query = Query.create(TABLE_ID)
.prefix("MTA/M86-SBS/1496275200000")
.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);