| 820 | return super().__hash__() |
| 821 | |
| 822 | def _to_proto_impl(self) -> DataSourceProto: |
| 823 | data_source_proto = DataSourceProto( |
| 824 | name=self.name, |
| 825 | type=DataSourceProto.STREAM_KINESIS, |
| 826 | field_mapping=self.field_mapping, |
| 827 | kinesis_options=self.kinesis_options.to_proto(), |
| 828 | description=self.description, |
| 829 | tags=self.tags, |
| 830 | owner=self.owner, |
| 831 | ) |
| 832 | |
| 833 | data_source_proto.timestamp_field = self.timestamp_field |
| 834 | data_source_proto.created_timestamp_column = self.created_timestamp_column |
| 835 | if self.batch_source: |
| 836 | data_source_proto.batch_source.MergeFrom(self.batch_source.to_proto()) |
| 837 | |
| 838 | return data_source_proto |
| 839 | |
| 840 | def source_type(self) -> DataSourceProto.SourceType.ValueType: |
| 841 | return DataSourceProto.STREAM_KINESIS |