Commit c5bc4cf1 authored by Heinz N. Gies's avatar Heinz N. Gies

Add tid forwardig

parent 1a106e13
......@@ -10,7 +10,8 @@
%%{qdate, "~>0.4.3"},
%%{erlware_commons, "~>1.0.0"},
{qdate, ".*", {git, "https://github.com/dalmatinerdb/qdate.git", {branch, "r19-dialyzer"}}},
{dproto, "~>0.4.0"},
{dproto, ".*", {git, "https://github.com/dalmatinerdb/dproto.git", {branch, "otters"}}},
%{dproto, "~>0.4.0"},
{mmath, "~>0.2.0"},
{hdr_histogram, "~>0.2.0"},
{otter, ".*", {git, "https://github.com/project-fifo/otter.git", {branch, "dev"}}},
......@@ -21,7 +22,8 @@
{dqe_idx, "~>0.2.0"},
{dqe_idx_ddb, "~>0.2.0"},
{dqe_idx_pg, "~>0.3.0"},
{ddb_connection, "~>0.2.0"}
{ddb_connection, ".*", {git, "https://github.com/dalmatinerdb/ddb_connection.git", {branch, "otters"}}}
%{ddb_connection, "~>0.2.0"}
]}.
{profiles,
......
{"1.1.0",
[{<<"cf">>,{pkg,<<"cf">>,<<"0.2.2">>},2},
{<<"ddb_client">>,{pkg,<<"ddb_client">>,<<"0.4.2">>},1},
{<<"ddb_connection">>,{pkg,<<"ddb_connection">>,<<"0.2.1">>},0},
{<<"ddb_client">>,
{git,"https://github.com/dalmatinerdb/ddb_client.git",
{ref,"b87b4d44ba7cd8ecd70e2c7dfc7a6f958fe03957"}},
1},
{<<"ddb_connection">>,
{git,"https://github.com/dalmatinerdb/ddb_connection.git",
{ref,"2990179dd52bdd626e8b8b94d3adbecab91b023c"}},
0},
{<<"dflow">>,
{git,"https://github.com/dalmatinerdb/dflow.git",
{ref,"10e5a2b8d056745fa6c258bbf8f88ced173b6f80"}},
0},
{<<"dproto">>,{pkg,<<"dproto">>,<<"0.4.1">>},0},
{<<"dproto">>,
{git,"https://github.com/dalmatinerdb/dproto.git",
{ref,"f68cba09c7be0682693b3b7d59d5e4bb183d551d"}},
0},
{<<"dqe_fun">>,
{git,"https://github.com/dalmatinerdb/dqe_fun.git",
{ref,"df01d5778b0dbc9523dcb387b0c59e34b48ada1f"}},
......@@ -38,9 +47,6 @@
[
{pkg_hash,[
{<<"cf">>, <<"7F2913FFF90ABCABD0F489896CFEB0B0674F6C8DF6C10B17A83175448029896C">>},
{<<"ddb_client">>, <<"C4D04B0621696A6F3A5FD0819125B11AB3EA0A01AB95F025CDC758ABF6275ECC">>},
{<<"ddb_connection">>, <<"7454EBF58BA6BDC7730B10D07269620B6AE5C61DEBDF8C40ADC0C60E4E1B07D3">>},
{<<"dproto">>, <<"A34C93BC248C9E06CF9098042EC14BB8B18A046FC5BFF986A128001F7E977C2F">>},
{<<"dqe_idx">>, <<"6BD1F0DE217DF0B213BD86CDBE19F5EEDBCAF0D5CBD51D955DB574A5C2DBA1EE">>},
{<<"dqe_idx_ddb">>, <<"2316B160D3EF3AAF2C60213A870D7B6A13C4035BF578DDC52301DA879099420C">>},
{<<"dqe_idx_pg">>, <<"5B93531BC946E53BED16947ADB01753F54DF6E057AD0B18AD13E603540C9A779">>},
......
......@@ -45,7 +45,7 @@ start(run,
dflow_span:log("read ~p @ ~p", [Chunk, Start]),
%% We do a bit of cheating here this allows us to loop.
State1 = State#state{start = Start + Chunk, count = Count - Chunk},
case ddb_connection:get(Bucket, Key, Start, Chunk) of
case ddb_connection:get(Bucket, Key, Start, Chunk, ottersp:ids()) of
{error, _Error} ->
dflow_span:log("read failed"),
{done, State};
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment