Я пытаюсь получить агрегированные данные, отправленные на разные выходы хранилища таблиц на основе имени столбца в запросе выбора. Я не уверен, возможно ли это с помощью потоковой аналитики. Я просмотрел документацию по потоковой аналитике и различные форумы, но пока не нашел потенциальных клиентов. Я ищу что-то вроде
Выберите tableName, подсчитать (отдельные записи) в tableName из inputStream
Я надеюсь, что это проясняет то, что я пытаюсь достичь, я пытаюсь вставить агрегаты данные в табличное хранилище (определяется как выходные данные). Я хочу получить выходной поток / имя табличного хранилища из выбранного запроса. Есть идеи, как это можно сделать?