curl --request POST \
--url https://dev.startree.ai/tables/{tableName}/restream \
--header 'Authorization: <api-key>'
{
"timeElapsedSinceStartInSeconds": 123,
"jobId": "<string>",
"stage": "INIT",
"restreamConfig": {
"debugPause": false,
"destTableNameWithType": "newTableName_REALTIME",
"maxRebalanceTimeMin": 120,
"destServerTenant": "restreamTenant",
"destBrokerTenant": "restreamTenant",
"maxTableStreamLag": 5000,
"tableNameWithType": "tableName_REALTIME"
},
"tableStreamProgress": {
"lastProbedLag": 123,
"lastProbeTimeMs": 123,
"startTime": 123
},
"verboseTableStreamLag": {},
"forceCommitProgress": {
"lastProbeTimeMs": 123,
"startTime": 123,
"totalConsumingSegments": 123,
"consumingSegmentsCommitted": 123
},
"segmentsToBeCommitted": [
"<string>"
]
}
Restream a table
curl --request POST \
--url https://dev.startree.ai/tables/{tableName}/restream \
--header 'Authorization: <api-key>'
{
"timeElapsedSinceStartInSeconds": 123,
"jobId": "<string>",
"stage": "INIT",
"restreamConfig": {
"debugPause": false,
"destTableNameWithType": "newTableName_REALTIME",
"maxRebalanceTimeMin": 120,
"destServerTenant": "restreamTenant",
"destBrokerTenant": "restreamTenant",
"maxTableStreamLag": 5000,
"tableNameWithType": "tableName_REALTIME"
},
"tableStreamProgress": {
"lastProbedLag": 123,
"lastProbeTimeMs": 123,
"startTime": 123
},
"verboseTableStreamLag": {},
"forceCommitProgress": {
"lastProbeTimeMs": 123,
"startTime": 123,
"totalConsumingSegments": 123,
"consumingSegmentsCommitted": 123
},
"segmentsToBeCommitted": [
"<string>"
]
}
The format of the key is "Basic <token>" or "Bearer <token>"
Name of the table with type to restream
Name of the destination table with type
Name of the tenant of the destination table
Name of the tenant of the destination table
Pause at start
Max TableStream Lag
Max Rebalance Time (Mins)
successful operation
The response is of type object
.