Оператор fork
Область применения: ✅Microsoft Fabric✅✅
Параллельно выполняет несколько операторов потребителей.
Синтаксис
T|
fork
[name]=
(
[)
name=
](
subquery ...)
Дополнительные сведения о соглашениях синтаксиса.
Параметры
Имя (название) | Type | Обязательно | Описание |
---|---|---|---|
subquery | string |
✔️ | Подчиненный конвейер поддерживаемых операторов запросов. |
name | string |
Временное имя для таблицы результатов вложенных запросов. |
Примечание.
- Избегайте использования
fork
с одним вложенным запросом. - Имя вкладки результатов совпадает с именем, указанным параметром
name
или операторомas
.
Поддерживаемые операторы запросов
as
count
extend
parse
where
take
project
project-away
project-keep
project-rename
project-reorder
summarize
top
top-nested
sort
mv-expand
reduce
Возвраты
Несколько таблиц результатов, по одному для каждого из аргументов вложенных запросов .
Советы
Используйте
materialize
в качестве замены ног илиjoin
union
на вилку. Входной поток кэшируется материализует, а затем кэшированное выражение можно использовать в ногах соединения или объединения.Используйте пакет с
materialize
операторами табличных выражений вместоfork
оператора.
Примеры
Примеры, приведенные в этой статье, используют общедоступные таблицы в кластера, например таблицу
StormEvents
в базе данных Samples.
В примерах этой статьи используются общедоступные таблицы, такие как таблица
StormEvents
в аналитике погоды примеры данных.
В примерах выводится несколько таблиц с именованными и именованными столбцами.
Неименованные вложенные запросы
StormEvents
| where State == "FLORIDA"
| fork
( where DeathsDirect + DeathsIndirect > 1)
( where InjuriesDirect + InjuriesIndirect > 1)
выходных
В этом выходных данных показаны первые несколько строк и столбцов результирующего таблицы.
StartTime | EndTime | EpisodeId | EventId | Государство | EventType | ТравмыDirect | ТравмыIndirect |
---|---|---|---|---|---|---|---|
2007-02-02T03:17:00Z | 2007-02-02T03:25:00Z | 3464 | 18948 | ФЛОРИДА | Торнадо | 10 | 0 |
2007-02-02T03:37:00Z | 2007-02-02T03:55:00Z | 3464 | 18950 | ФЛОРИДА | Торнадо | 9 | 0 |
2007-03-13T08:20:00Z | 2007-03-13T08:20:00Z | 4094 | 22961 | ФЛОРИДА | Плотный туман | 3 | 0 |
2007-09-11T15:26:00Z | 2007-09-11T15:26:00Z | 9578 | 53798 | ФЛОРИДА | Rip Current | 0 | 0 |
Именованные вложенные запросы
В следующих примерах таблица результатов называется StormsWithDeaths и StormsWithInjuries.
StormEvents
| where State == "FLORIDA"
| fork
(where DeathsDirect + DeathsIndirect > 1 | as StormsWithDeaths)
(where InjuriesDirect + InjuriesIndirect > 1 | as StormsWithInjuries)
StormEvents
| where State == "FLORIDA"
| fork
StormsWithDeaths = (where DeathsDirect + DeathsIndirect > 1)
StormsWithInjuries = (where InjuriesDirect + InjuriesIndirect > 1)
выходных
В этом выходных данных показаны первые несколько строк и столбцов результирующего таблицы.
StartTime | EndTime | EpisodeId | EventId | Государство | EventType | ТравмыDirect | ТравмыIndirect |
---|---|---|---|---|---|---|---|
2007-02-02T03:17:00Z | 2007-02-02T03:25:00Z | 3464 | 18948 | ФЛОРИДА | Торнадо | 10 | 0 |
2007-02-02T03:37:00Z | 2007-02-02T03:55:00Z | 3464 | 18950 | ФЛОРИДА | Торнадо | 9 | 0 |
2007-03-13T08:20:00Z | 2007-03-13T08:20:00Z | 4094 | 22961 | ФЛОРИДА | Плотный туман | 3 | 0 |
2007-09-11T15:26:00Z | 2007-09-11T15:26:00Z | 9578 | 53798 | ФЛОРИДА | Rip Current | 0 | 0 |