Repository: spark
Updated Branches:
refs/heads/master 61f9c8711 -> 26062d226
[SPARK-11198][STREAMING][KINESIS] Support de-aggregation of records during
recovery
While the KCL handles de-aggregation during the regular operation, during
recovery we use the lower level api, and therefore need
Repository: spark
Updated Branches:
refs/heads/branch-1.6 34e824d90 -> 116b7158f
[SPARK-11198][STREAMING][KINESIS] Support de-aggregation of records during
recovery
While the KCL handles de-aggregation during the regular operation, during
recovery we use the lower level api, and therefore