如何访问windowStartTime?
How to access windowStartTime?
我想使用 windowStartTime 参数访问使用基于日期的文件夹结构的文件。
我有以下触发器:
{
"name": "trigger1",
"properties": {
"annotations": [],
"runtimeState": "Started",
"pipeline": {
"pipelineReference": {
"referenceName": "Neil_Test",
"type": "PipelineReference"
},
"parameters": {
"Window1": {
"type": "Expression",
"value": "@{trigger().outputs.windowStartTime}"
}
}
},
"type": "TumblingWindowTrigger",
"typeProperties": {
"frequency": "Hour",
"interval": 24,
"startTime": "2019-08-30T00:00:00.000Z",
"delay": "00:00:00",
"maxConcurrency": 1,
"retryPolicy": {
"intervalInSeconds": 30
},
"dependsOn": []
}
}
}
这会将管道对象上的 Window1
参数设置为 NULL
。
如何将 windowStartTime 参数的实际值放入我的管道?
您在这里发布的是 {}。这个对我来说很好用:
{
"name": "triggerwin",
"properties": {
"annotations": [],
"runtimeState": "Started",
"pipeline": {
"pipelineReference": {
"referenceName": "setVar",
"type": "PipelineReference"
},
"parameters": {
"FileName": "@trigger().outputs.windowStartTime"
}
},
"type": "TumblingWindowTrigger",
"typeProperties": {
"frequency": "Minute",
"interval": 15,
"startTime": "2019-09-02T00:00:00.000Z",
"delay": "00:00:00",
"maxConcurrency": 50,
"retryPolicy": {
"intervalInSeconds": 30
},
"dependsOn": []
}
}
}
希望对您有所帮助!!
我想使用 windowStartTime 参数访问使用基于日期的文件夹结构的文件。
我有以下触发器:
{
"name": "trigger1",
"properties": {
"annotations": [],
"runtimeState": "Started",
"pipeline": {
"pipelineReference": {
"referenceName": "Neil_Test",
"type": "PipelineReference"
},
"parameters": {
"Window1": {
"type": "Expression",
"value": "@{trigger().outputs.windowStartTime}"
}
}
},
"type": "TumblingWindowTrigger",
"typeProperties": {
"frequency": "Hour",
"interval": 24,
"startTime": "2019-08-30T00:00:00.000Z",
"delay": "00:00:00",
"maxConcurrency": 1,
"retryPolicy": {
"intervalInSeconds": 30
},
"dependsOn": []
}
}
}
这会将管道对象上的 Window1
参数设置为 NULL
。
如何将 windowStartTime 参数的实际值放入我的管道?
您在这里发布的是 {}。这个对我来说很好用:
{
"name": "triggerwin",
"properties": {
"annotations": [],
"runtimeState": "Started",
"pipeline": {
"pipelineReference": {
"referenceName": "setVar",
"type": "PipelineReference"
},
"parameters": {
"FileName": "@trigger().outputs.windowStartTime"
}
},
"type": "TumblingWindowTrigger",
"typeProperties": {
"frequency": "Minute",
"interval": 15,
"startTime": "2019-09-02T00:00:00.000Z",
"delay": "00:00:00",
"maxConcurrency": 50,
"retryPolicy": {
"intervalInSeconds": 30
},
"dependsOn": []
}
}
}
希望对您有所帮助!!