[
https://issues.apache.org/jira/browse/BEAM-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079364#comment-17079364
]
Michał Walenia commented on BEAM-9147:
--------------------------------------
[~Sanith_h] thanks for the explanation. I think we're touching a third meaning
of streaming here :)
In Beam context, if you have eg. a repository of videos on GCS and watch the
bucket with FileIO, you can easily stream addresses or contents of the files
into my transform and receive correct results (I think).
If you wanted to optimize the performance and cut the files in order to use the
StreamingVideoIntelligenceServiceClient, you'd need to implement this kind of
transform yourself - my set of transforms doesn't support this type of
operation. It would be an interesting addition though.
As for your problems with running the pipeline - can you give me an example
pipeline that reproduces the error? I'll be glad to investigate it further and
help you.
> [Java] PTransform that integrates Video Intelligence functionality
> ------------------------------------------------------------------
>
> Key: BEAM-9147
> URL: https://issues.apache.org/jira/browse/BEAM-9147
> Project: Beam
> Issue Type: Sub-task
> Components: io-java-gcp
> Reporter: Kamil Wasilewski
> Assignee: Michał Walenia
> Priority: Major
> Fix For: 2.21.0
>
> Time Spent: 3h
> Remaining Estimate: 0h
>
> The goal is to create a PTransform that integrates Google Cloud Video
> Intelligence functionality [1].
> The transform should be able to take both video GCS location or video data
> bytes as an input.
> A module with the transform should be put into _`sdks/java/extensions`_
> folder.
> [1] [https://cloud.google.com/video-intelligence/]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
