[Data Flow/Ingestion] Schema declaration/registration