riteshghorse commented on code in PR #29782:
URL: https://github.com/apache/beam/pull/29782#discussion_r1446540352
##########
sdks/python/apache_beam/transforms/enrichment.py:
##########
@@ -15,47 +15,48 @@
# limitations under the License.
#
+from typing import Any
from typing import Callable
-from typing import Generic
+from typing import Dict
from typing import Optional
+from typing import Tuple
from typing import TypeVar
import apache_beam as beam
from apache_beam.io.requestresponse import DEFAULT_TIMEOUT_SECS
-from apache_beam.io.requestresponse import CacheReader
-from apache_beam.io.requestresponse import CacheWriter
from apache_beam.io.requestresponse import Caller
-from apache_beam.io.requestresponse import PreCallThrottler
-from apache_beam.io.requestresponse import Repeater
from apache_beam.io.requestresponse import RequestResponseIO
-from apache_beam.io.requestresponse import ShouldBackOff
__all__ = [
"EnrichmentSourceHandler",
"Enrichment",
+ "cross_join",
]
InputT = TypeVar('InputT')
OutputT = TypeVar('OutputT')
+JoinFn = Callable[[Tuple[Dict[str, Any], Dict[str, Any]]], beam.Row]
Review Comment:
I agree, thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
